44a09fdb19ec401324a90875f5d8f793b62cd2ac,modules/core/src/main/java/org/gridgain/grid/kernal/processors/hadoop/hadoop1impl/GridHadoopV1CombineTask.java,GridHadoopV1CombineTask,run,#GridHadoopTaskContext#,31
Before Change
@Override public void run(final GridHadoopTaskContext taskCtx) throws GridInterruptedException, GridException {
GridHadoopV1JobImpl jobImpl = (GridHadoopV1JobImpl)taskCtx.job();
JobContext jobCtx = jobImpl.hadoopJobContext();
Reducer combiner = U.newInstance(jobCtx.getJobConf().getCombinerClass());
combiner.configure(jobCtx.getJobConf());
GridHadoopTaskInput input = taskCtx.input();
After Change
@Override public void run(final GridHadoopTaskContext taskCtx) throws GridInterruptedException, GridException {
GridHadoopV2JobImpl jobImpl = (GridHadoopV2JobImpl) taskCtx.job();
JobConf jobConf = jobImpl.hadoopJobContext().getJobConf();
Reducer combiner = U.newInstance(jobConf.getCombinerClass());